package com.gzx.qc.modular.text.service;

import com.gzx.qc.modular.text.vo.GzxAsrVoiceTextVo;
import org.apache.kafka.clients.consumer.ConsumerRecord;

import java.util.List;

/**
 * @author xbl
 */
public interface GzxAsrVoiceTextService {

    /**
     * 获取最大已处理完成的数据里最大的话单id
     */
    int getMaxVoiceId();

    //批量入库
    void batchInsert(List<GzxAsrVoiceTextVo> textList);

    //kafka消费
    void kafkaConsumer(List<ConsumerRecord<String, String>> recordList);

    /**
     * 根据CallID获取asr通话文本
     */
    List<GzxAsrVoiceTextVo> getTextByCallId(String callId);
}
